package com.lz.redis.common.redis.queue;

import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;

/**
 * 发布类（Publisher）
 * 用于将消息发送到Redis指定的频道上。
 * */
@Component
public class RedisPublisher {
    @Resource
    private RedisTemplate<String, String> redisTemplate;
    public void publish(String channel, String message) {
        redisTemplate.convertAndSend(channel, message);
    }
}